package com.ds.lens.flink.monitor.monitorjob.function;

import com.ds.lens.flink.monitor.common.bo.MetricBundle;
import org.apache.flink.api.java.functions.KeySelector;

public class MetricKeySelector implements KeySelector<MetricBundle, Long> {
    @Override
    public Long getKey(MetricBundle value) throws Exception {
        return value.getState().getKey().getMonitorId();
    }
}
